package cn.tang.tframe.mq;

/**
 * Created by tanghc on 17/2/3.
 */

import cn.tang.tframe.mq.producer.QtProducerClient;

public class QtKafkaProducerExample {
	public static void main(String[] args) throws InterruptedException {
		QtProducerClient.getQtProducer().sendSync("t1", "abc");
		QtProducerClient.getQtProducer().sendSync("t1", "abc");
		QtProducerClient.getQtProducer().sendSync("t1", "abc");
		Thread.sleep(1000);
		QtProducerClient.getQtProducer().sendSync("t1", "abc1");
		QtProducerClient.getQtProducer().sendSync("t1", "abc1");
		QtProducerClient.getQtProducer().sendSync("t1", "abc1");
		QtProducerClient.getQtProducer().sendSync("t1", "abc1");
	}
}